Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

【Abondoned for commit too large】:decoupling apiserver and clustersynchro-manager by message midd… #1

Open
wants to merge 1 commit into
base: main
Choose a base branch
from

Conversation

zhouhaoA1
Copy link
Collaborator

…leware

What type of PR is this?
/kind feature

What this PR does / why we need it:
decoupling apiserver and clustersynchro-manager by message middware

Which issue(s) this PR fixes:
Fixes #

Special notes for your reviewer:

Does this PR introduce a user-facing change?:


@@ -45,13 +51,32 @@ type Options struct {
KubeStateMetrics *kubestatemetrics.Options

WorkerNumber int // WorkerNumber is the number of worker goroutines
Publisher *watchoptions.MiddlerwareOptions
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

middleware to messagequeue?

Copy link
Collaborator Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

middleware better


options.BindLeaderElectionFlags(&o.LeaderElection, genericfs)

fs := fss.FlagSet("misc")
fs.StringVar(&o.Master, "master", o.Master, "The address of the Kubernetes API server (overrides any value in kubeconfig).")
fs.StringVar(&o.Kubeconfig, "kubeconfig", o.Kubeconfig, "Path to kubeconfig file with authorization and master location information.")
fs.StringVar(&o.Kubeconfig, "manager-kubeconfig", o.Kubeconfig, "Path to kubeconfig file with authorization and master location information.")
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

why do you modify the current kueconfig key

Copy link
Collaborator Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

ok, i will fix it.

"strings"
)

func GetShardingTable(gvr schema.GroupVersionResource) string {
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

What does GetShardingTable work for

@wuyingjun-lucky
Copy link
Member

please run make lint on your local Desktop

@zhouhaoA1 zhouhaoA1 force-pushed the dev_messagequeue branch 16 times, most recently from 1eb08d9 to 4177173 Compare October 30, 2023 06:57
@zhouhaoA1 zhouhaoA1 force-pushed the dev_messagequeue branch 2 times, most recently from 7eebc7d to 21084f6 Compare October 31, 2023 06:48
@zhouhaoA1 zhouhaoA1 changed the title decoupling apiserver and clustersynchro-manager by message midd… 【Abondoned for commit too large】:decoupling apiserver and clustersynchro-manager by message midd… Nov 9, 2023
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants